import lib.workflow
import os
import time
import datetime
import sys
import logging
from google.appengine.ext import webapp
from google.appengine.ext.webapp import util
from google.appengine.ext import db
from google.appengine.api import datastore_errors
from model.models import *
from lib.workflow import *

class Processor():
  
      def execute(self):
	  logging.debug("Executing processor")
	  self.internal_execute()
      pass
class AuthorizeProjectLeaderProcessor(Processor):
  
      def internal_execute(self):
	pass

class WorkflowManager():
  
  def getProcessorForStep(self,step_name):
    logging.debug("Looking for processor for step "  + step_name)
    if(step_name == "PSWENotifyProjectLeader"):
      return AuthorizeProjectLeaderProcessor() 
    return None
  